package uk.co.cocking.getinline2.pipeline;

import uk.co.cocking.getinline2.exceptions.EnvironmentException;


public interface Consumer<SinkType> {

   void open() throws EnvironmentException;
   void process(SinkType... items) throws EnvironmentException;
   void close() throws EnvironmentException;

}
